package com.lmn.stream.rocketmq;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 通过@Output注解，声明了一个名字为login_topic的 Output Binding。
 * 注意:这个名字要和我们配置文件中的 spring.cloud.stream.bindings 配置项对应上
 * @Output 注解的方法的返回结果为 MessageChannel 类型，可以使用它发送消息。
 */
public interface Source {

    @Output(MyTopic.LOGIN)
    MessageChannel login();

}
